/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */

package DA;

import BE.BELineaMovimiento;
import BE.BEPallet;
import BL.BLPallet;
import java.sql.Connection;
import java.sql.PreparedStatement;

import java.sql.ResultSet;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;
import javax.swing.JOptionPane;

/**
 *
 * @author Cristian
 */
public class DALineaMovimiento {
public void agregarLineaMovimiento (BELineaMovimiento objLineaMovimiento, int idmov)
   {

        DAConexion bd = new DAConexion();
        Connection con = null;
        Statement s = null;
        ResultSet rs = null;

        
        try
        {
            con = bd.conectar();
            
            //JOptionPane.showMessageDialog(null,"Hola mundo","Error",JOptionPane.ERROR_MESSAGE);
            String query = "INSERT INTO lineaMovimiento (idlineamovimiento,idmovimiento,idpallet,cantidad)VALUES (?,?,?,?)";
                PreparedStatement p=con.prepareStatement(query);
            p.setInt(1,objLineaMovimiento.getIdLineaMovimiento() );
                p.setInt(2, idmov);
            p.setInt(3, objLineaMovimiento.getPallet().getIdPallet());

            p.setInt(4, objLineaMovimiento.getCantidad());

            //JOptionPane.showMessageDialog(null,p.toString(),"Error",JOptionPane.ERROR_MESSAGE);
            p.execute();

                BLPallet blpallet =new BLPallet();
            blpallet.cambiarEstado(objLineaMovimiento.getPallet().getIdPallet(),objLineaMovimiento.getPallet().getEstado());
            

        } catch (Exception e) {
            JOptionPane.showMessageDialog(null,"Problema al consultar la base de datos"+e.toString(),"Error",JOptionPane.ERROR_MESSAGE);
            bd.cierraConexion(con);
        }
        bd.cierraConexion(con);

    }
public List<BELineaMovimiento> buscarByMovimiento(int mov)
    {
        DAConexion bd = new DAConexion();
        Connection con = null;
        ResultSet rs = null;
        Statement s = null;
     
String query;
             query = "SELECT * FROM lineamovimiento Where idmovimiento =" + mov  ;

 List <BELineaMovimiento> lslineamov;
        try
        {
            con = bd.conectar();
            s = con.createStatement();
            rs = s.executeQuery(query);
            lslineamov = new ArrayList<BELineaMovimiento>();

            while (rs.next()){
                BLPallet blpallet = new BLPallet();
                    BEPallet objpallet= new BEPallet();
                    objpallet= blpallet.getPalletbyId(rs.getInt(3));
                lslineamov.add(new BELineaMovimiento(rs.getInt(1),rs.getInt(2),objpallet,rs.getInt(4)));
            }



        } catch (Exception e) {
            JOptionPane.showMessageDialog(null,"Problema al consultar la base de datos","Error",JOptionPane.ERROR_MESSAGE);
            bd.cierraConexion(con);
            return null;
        }
        bd.cierraConexion(con);
        return lslineamov;
    }







}
